package com.example.entity;

import com.google.common.collect.Maps;

import javax.websocket.RemoteEndpoint;
import javax.websocket.Session;
import java.util.Map;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * 记录socket数据
 *
 * @author zy
 */
public class SocketEntity {
    /**
     * 静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
     */
    public static volatile AtomicInteger ONLINE_COUNT = new AtomicInteger(0);

    /**
     * concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。
     */
    public static final Map<RemoteEndpoint.Basic, Session> SESSION_CURRENT_MAP = Maps.newConcurrentMap();
}
